package Thread;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingDeque;
import java.util.concurrent.BlockingQueue;

public class TreadDemo24 {
    public static void main(String[] args) throws InterruptedException {
        BlockingQueue<String> queue=new ArrayBlockingQueue<>(100);
        queue.put("aaa");//使用的put和offer一样都是入队列，但是put带有阻塞功能，offer没带阻塞，队列满了会返回一个结果true/false
        String elem=queue.take();//take()方法用来出队列，也是带有阻塞功能的
        System.out.println("elem="+elem);
        elem=queue.take();
        System.out.println("elem"+elem);
    }
}
